

import java.io.*;
import java.net.*;
import java.util.Scanner;
public class Client {
   public static void main(String args[]) throws IOException{
      String [] mess ={"早饭吃了吗?","要不要一起吃?","那我一个人去吃了。"};
      Socket mysocket=null;
	  //（2）在Socket通道内通过IO进行数据的读取和写入。
      DataInputStream in=null;
      DataOutputStream out=null;
      try{  //（1）建立客户端的Socket服务,并明确要连接的服务器和端口号。
	        mysocket=new Socket("127.0.0.1",2010);
			//（3）通过Socket对象的方法getInputStream()和getOutputStream()，可以获取这两个流。
            in=new DataInputStream(mysocket.getInputStream());
            out=new DataOutputStream(mysocket.getOutputStream()); 
            while(true) {
			  //（4）通过流的对象可以对数据进行传输（读取和写入）。
            	Scanner s2=new Scanner(System.in);
              String s1=s2.next();
              out.writeUTF(s1);
              String  s=in.readUTF();   //in读取信息，堵塞状态
			  Thread.sleep(2000);
              System.out.println("客户收到服务器的回答:"+s);
              
            } 
       }
       catch(Exception e) {
            System.out.println("服务器已断开"+e);
       }
	   //（5）如果传输数据完毕，关闭资源。
	   mysocket.close();
   } 
}
